package com.galudisu.materializer

import akka.NotUsed
import akka.actor.ActorSystem
import akka.stream._
import akka.stream.scaladsl.{Sink, Source}

object Module extends App {
  implicit val system       = ActorSystem("QuickStart")
  implicit val materializer = ActorMaterializer()
  implicit val ec           = system.dispatcher

  // source
  val source: Source[Int, NotUsed] = Source(1 to 100)

  // sink
  val sink1 = Sink.foreach(println)
  val sink2 = Sink.foreach(println)

  // flow
  //  val triodeFlow = source.con(sink1,sink2)

}

